package com.sheepone.distributor.test;

import com.sheepone.distributor.DistributorApplication;
import com.sheepone.distributor.anno.StationEventTopicListener;
import com.sheepone.distributor.listener.StationEventListener;

/**
 * @author Miss.杨
 * @description
 * @since 2024/3/24 - 10:11
 */@StationEventTopicListener(station = StationConstants.DELAY, topic = TopicConstants.DELAY)
public class DelayEventListener implements StationEventListener<StringContext> {
    @Override
    public void onEvent(StringContext context) {
        DistributorApplication.read.increment();
        System.err.println("accept delay event,value is = " + context.getValue());
    }
}
